2a0c08b27355eb6035bf4551ea6207b4a440ecd4,central/src/main/java/org/glowroot/central/GrpcServer.java,CollectorServiceImpl,collectGaugeValues,#GaugeValueMessage#StreamObserver#,305
Before Change
StreamObserver<EmptyMessage> responseObserver) {
long maxCaptureTime = 0;
try {
gaugeValueDao.store(request.getAgentId(), request.getGaugeValuesList());
for (GaugeValue gaugeValue : request.getGaugeValuesList()) {
maxCaptureTime = Math.max(maxCaptureTime, gaugeValue.getCaptureTime());
}
} catch (Throwable t) {
logger.error("{} - {}", request.getAgentId(), t.getMessage(), t);
responseObserver.onError(t);
return;
}
try {
heartbeatDao.store(request.getAgentId());
} catch (Throwable t) {
logger.error("{} - {}", request.getAgentId(), t.getMessage(), t);
responseObserver.onError(t);
return;
}
String agentDisplay = agentDao.readAgentRollupDisplay(request.getAgentId());
checkGaugeAlerts(request.getAgentId(), agentDisplay, maxCaptureTime);
clearHeartbeatAlerts(request.getAgentId(), agentDisplay);
responseObserver.onNext(EmptyMessage.getDefaultInstance());
responseObserver.onCompleted();
After Change
@Override
public void collectGaugeValues(GaugeValueMessage request,
StreamObserver<EmptyMessage> responseObserver) {
String agentId = request.getAgentId();
long maxCaptureTime = 0;
try {
gaugeValueDao.store(agentId, request.getGaugeValuesList());